package com.qf.work;

import com.qf.utils.ConnectionUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

/**
 * @author 郗昊天
 * @version 1.0
 * @package com.qf.simple
 * @date 2022/10/14 20:34
 */
public class  Sender {

    private static final String QUEUENAME="xht";
    public static void main(String[] args) throws Exception {
        //获取连接
        Connection connection = ConnectionUtils.getconnection();
        //创建通道
        Channel channel = connection.createChannel();
        //声明队列
        //参数1  队列的名字
        //2  是否是持久化队列  TRUE则保存到磁盘上
        //3  是否排外 为true则不允许的多个连接 否则抛异常
        //4 自动删除  true时，没有未消费的消息或者无客户端连接的情况下自动删除
        //5  一些额外的创建参数
        channel.queueDeclare(QUEUENAME,false,false,false,null);
        //发送消息

        for (int i = 0; i < 50; i++) {
            String msg="贺小倩喊你回家吃饭"+i;
            channel.basicPublish("", QUEUENAME, null, msg.getBytes());
        }

        //用不到就是关闭
        channel.close();
        connection.close();

    }
}
